package com.udf.flink.udsf;

import org.apache.flink.table.functions.ScalarFunction;


/**
 * 自定义函数测试
 */
public class StrUdf extends ScalarFunction{

//    public StrUdf() {}

//    public String eval(String user) {
//        if (StringUtils.isNoneBlank(user)) {
//            return "udf" + user;
//        }
//        return null;
//    }
    public String eval(String s, Integer begin, Integer end) {
        return s.substring(begin, end);
    }
//
//    public static void main(String[] args) {
//
//    }
}
